package com.cfh.springcloudserver.stream;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

public interface SimpleMessageSink {
    /**
     * Input channel name.
     */
    String INPUT = "gupao2018";

    /**
     * @return input channel.
     */
    @Input(SimpleMessageSink.INPUT)
    SubscribableChannel input();

    @Input("test007")
    SubscribableChannel testInput();
}
